package com.example;

public class KafkaProducerDemo {
    public static void main(String[] args) {
        Producer producer = new ProducerImpl();
        for (int i = 0; i < 10; ++i) {
            producer.send(new Order(1000L + i, System.currentTimeMillis(), "USD2CNY", 6.5d));
            producer.send(new Order(2000L + i, System.currentTimeMillis(), "USD2CNY", 6.51d));
        }
        producer.waitComplete();
    }
}
